SparkEnv.get.serializerManager
SerializerManager
|
Caution
|
FIXME |
When SparkEnv is created (either for the driver or executors), it instantiates SerializerManager that is then used to create a BlockManager.
It automatically selects the best serializer which is KryoSerializer whenever possible or falls backs to the input defaultSerializer serializer.
The common idiom in Spark’s code is to access the current SerializerManager using SparkEnv.
getSerializer Method
|
Caution
|
FIXME |
dataDeserializeStream Method
|
Caution
|
FIXME |
Automatic Selection of Best Serializer
|
Caution
|
FIXME |
Settings
| Name | Default value | Description |
|---|---|---|
|
The flag to enable IO encryption |
|
|
|
The flag to control whether to compress shuffle output when stored |
|
|
The flag to control whether to compress RDD partitions when stored serialized. |
|
|
The flag to control whether to compress shuffle output temporarily spilled to disk. |
|